package org.jseda.stage;

import org.jseda.Processor;
import org.jseda.Publisher;
import org.jseda.queue.Queue;

public class DefaultProcessingStage<T, V> implements ProcessingStage<T, V>
{
  private Queue<T> _queue;
  private Publisher<V> _publisher;
  private Processor<T, V> _processor;

  public void sendWork(T workUnit)
  {
    _queue.pushBack(workUnit);
  }

  public void setQueue(Queue<T> queue)
  {
    _queue = queue;
  }
  
  public void setPublisher(Publisher<V> publisher)
  {
    _publisher = publisher;
  }

  public void setProcessor(Processor<T, V> processor)
  {
    _processor = processor;
  }
}
